from pyspark import SparkConf, SparkContext

conf = SparkConf().setMaster("local[*]").setAppName("test_spark")
sc = SparkContext(conf=conf)

rdd = sc.textFile("D:/dev/python/python-heima-caoyu/rdd_text.txt")
print(rdd.collect())